package com.github.ghsea.kafka.config;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.PropertySource;

/**
 * @author guhai
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@ConfigurationProperties(prefix = "kafka.consumer")
@PropertySource("classpath:application.yml")
public class ConsumerProperties {

    private String groupId;

    /**
     * 是否启动自动提交ack
     */
    private boolean enableAutoCommit;

    private String autoCommitIntervalMs;

    private String autoOffsetReset;


    /**
     * keyDeserializer
     */
    private String keyDeserializer;

    /**
     * valueDeserializer
     */
    private String valueDeserializer;

    /**
     * 隔离级别
     */
    private String isolationLevel;

    private Integer partitionNum;

}
